package com.icedata.sika.core

import okhttp3.internal.notifyAll


/**
 * 异常处理器链，用于挂载异常处理器
 */
class ExceptionProcessorBus(sika: Sika) : ProcessorBus<ExceptionProcessor, Exception, Unit>(sika) {

    /**
     * 广播一个异常
     */
    override fun broadcast(data: Exception) {
        for (p in processors)
            p.execute(data, sika)
        synchronized(lock) {
            lock.notifyAll()
        }
    }
}